from sqlalchemy.ext.asyncio import create_async_engine, async_sessionmaker
from app.models.base import Base

engine = create_async_engine("sqlite+aiosqlite:///my_account.db")

Session = async_sessionmaker(bind=engine)


async def create_all():
    from . import async_test

    async with engine.begin() as conn:
        await conn.run_sync(Base.metadata.create_all)
